e0f80fd0114aa7acf9c693be119a21e603469a12,rheem-core/src/main/java/org/qcri/rheem/core/function/AggregationDescriptor.java,AggregationDescriptor,AggregationDescriptor,#DataUnitGroupType#BasicDataUnitType#,21
Before Change
public AggregationDescriptor(DataUnitGroupType<InputType> inputType, BasicDataUnitType<OutputType> outputType) {
this(inputType, outputType,
LoadEstimator.createFallback(1, 1),
LoadEstimator.createFallback(1, 1));
}
public AggregationDescriptor(Class<InputType> inputTypeClass, Class<OutputType> outputTypeClass) {
After Change
// TODO: What about aggregation functions?
public AggregationDescriptor(DataUnitGroupType<InputType> inputType, BasicDataUnitType<OutputType> outputType) {
this(inputType, outputType, new NestableLoadProfileEstimator(
LoadEstimator.createFallback(1, 1),
LoadEstimator.createFallback(1, 1)
));
}
public AggregationDescriptor(Class<InputType> inputTypeClass, Class<OutputType> outputTypeClass) {